ca4dc791cd54df31e6582839f63e30ff4961593c,test/freenet/client/async/SplitFileInserterStorageTest.java,SplitFileInserterStorageTest,testRepeatedEncodeAfterShutdownCrossSegment,#number#,768

Before Change


        // Has not encoded anything.
        for(SplitFileInserterSegmentStorage segment : storage.segments)
            assert(!segment.isFinishedEncoding());
        SplitFileInserterStorage resumed = new SplitFileInserterStorage(storage.getRAF(), data, cb, r, 
                memoryLimitedJobRunner, jobRunner, ticker, keys, fg, persistentFileTracker);
        resumed.start();
        // The memoryLimitedJobRunner will only encode one segment at a time.
        // Wait for it to encode one segment.
        memoryLimitedJobRunner.shutdown();

After Change


        SplitFileInserterStorage resumed = null;
        if(storage.crossSegments != null) {
            for(int i=0;i<storage.crossSegments.length;i++) {
                memoryLimitedJobRunner = new MemoryLimitedJobRunner(9*1024*1024L, 1, executor);
                resumed = new SplitFileInserterStorage(storage.getRAF(), data, cb, r, 
                        memoryLimitedJobRunner, jobRunner, ticker, keys, fg, persistentFileTracker);
                assertEquals(i, countEncodedCrossSegments(resumed));
                resumed.start();
                // The memoryLimitedJobRunner will only encode one segment at a time.
                // Wait for it to encode one segment.
                memoryLimitedJobRunner.shutdown();